package com.lee.rabbitmq.service;

import org.springframework.amqp.rabbit.annotation.RabbitListener;

/**
 * 接收类
 *
 * @author Lee
 * @createDate 2021/12/17 11:05
 */
public interface ReceiveService {
    /**
     * 接收方法
     * 这里个接收不是不间断接收消息，每执行一次这个方法只能接收一次消息，如果有新消息进
     * 则不会自动接收消息,不建议使用
     * @author Lee
     * @createDate 2021/12/17 11:07
     */
    void receive();

    /**
     * 持续性监听队列
     * @param message 接收到的具体消息
     * @author Lee
     * @createDate 2021/12/17 11:28
     */
    void directReceive(String message);

}
